package com.beiding.config;

import com.beiding.utils.AmqpUtils;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class Queues {
    @Bean
    public Queue deleteUser()
    {
        return AmqpUtils.createQueue("ua.deleteUser.async");
    }



    @Bean
    public Queue landlord() {
        return AmqpUtils.createQueue("message.send.landlord");
    }

    @Bean
    public Queue tenant() {
        return AmqpUtils.createQueue("message.send.tenant");
    }


}
